﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Common.RabbitMQ
{
    public interface IRabbitMqService
    {
        Task<string> ConsumeMessage(string exchange, string queueName, string routingKey, string type = "fanout");

        Task PublishMessage(string exchange, string queueName, string message, string routingKey, string type = "fanout");

        Task SubscribeMessage(string exchange, string queueName, string routingKey, Action<string> del, string type = "direct");
    }
}
